const fs = require('fs');
const path = require('path');

const FILE_PATH = path.join(__dirname, 'data.txt');

// 确保文件存在，如果不存在则创建该文件
if (!fs.existsSync(FILE_PATH)) {
    fs.writeFileSync(FILE_PATH, ''); // 新建文件并初始化为空
}

// 模拟WebSocket接收消息的函数
function simulateWebSocketMessages() {
    // 生成虚拟消息
    const message = `新消息: ${new Date().toLocaleTimeString()}`;

    // 将消息写入到data.txt文件中
    fs.appendFile(FILE_PATH, message + '\n', (err) => {
        if (err) {
            console.error('写入文件错误:', err);
        } else {
            console.log('消息已写入文件:', message);
        }
    });
}

// 定时器每2秒生成一次消息
setInterval(simulateWebSocketMessages, 2000);

console.log('模拟WebSocket消息发送，消息将被写入data.txt');
